github.com/jackc/pgx/v5/pgconn.Pipeline.conn (field)
52 uses
github.com/jackc/pgx/v5/pgconn (current package)
pgconn.go#L2192: conn *PgConn
pgconn.go#L2370: conn: pgConn,
pgconn.go#L2398: p.conn.frontend.SendParse(&pgproto3.Parse{Name: name, Query: sql, ParameterOIDs: paramOIDs})
pgconn.go#L2399: p.conn.frontend.SendDescribe(&pgproto3.Describe{ObjectType: 'S', Name: name})
pgconn.go#L2409: p.conn.frontend.SendClose(&pgproto3.Close{ObjectType: 'S', Name: name})
pgconn.go#L2419: p.conn.frontend.SendParse(&pgproto3.Parse{Query: sql, ParameterOIDs: paramOIDs})
pgconn.go#L2420: p.conn.frontend.SendBind(&pgproto3.Bind{ParameterFormatCodes: paramFormats, Parameters: paramValues, ResultFormatCodes: resultFormats})
pgconn.go#L2421: p.conn.frontend.SendDescribe(&pgproto3.Describe{ObjectType: 'P'})
pgconn.go#L2422: p.conn.frontend.SendExecute(&pgproto3.Execute{})
pgconn.go#L2432: p.conn.frontend.SendBind(&pgproto3.Bind{PreparedStatement: stmtName, ParameterFormatCodes: paramFormats, Parameters: paramValues, ResultFormatCodes: resultFormats})
pgconn.go#L2433: p.conn.frontend.SendDescribe(&pgproto3.Describe{ObjectType: 'P'})
pgconn.go#L2434: p.conn.frontend.SendExecute(&pgproto3.Execute{})
pgconn.go#L2444: p.conn.frontend.SendBind(&pgproto3.Bind{PreparedStatement: statementDescription.Name, ParameterFormatCodes: paramFormats, Parameters: paramValues, ResultFormatCodes: resultFormats})
pgconn.go#L2445: p.conn.frontend.SendExecute(&pgproto3.Execute{})
pgconn.go#L2462: p.conn.frontend.Send(&pgproto3.Flush{})
pgconn.go#L2477: p.conn.frontend.SendSync(&pgproto3.Sync{})
pgconn.go#L2490: err := p.conn.flushWithPotentialWriteReadDeadlock()
pgconn.go#L2494: p.conn.asyncClose()
pgconn.go#L2496: p.conn.contextWatcher.Unwatch()
pgconn.go#L2497: p.conn.unlock()
pgconn.go#L2528: if !p.conn.resultReader.closed {
pgconn.go#L2529: _, err := p.conn.resultReader.Close()
pgconn.go#L2647: fieldDescriptions := p.conn.getFieldDescriptionSlice(len(sdFields))
pgconn.go#L2656: pgConn: p.conn,
pgconn.go#L2662: p.conn.resultReader = rr
pgconn.go#L2663: return &p.conn.resultReader, nil
pgconn.go#L2665: p.conn.resultReader = ResultReader{
pgconn.go#L2666: commandTag: p.conn.makeCommandTag(msg.CommandTag),
pgconn.go#L2671: return &p.conn.resultReader, nil
pgconn.go#L2675: p.conn.resultReader.closed = true
pgconn.go#L2694: p.conn.resultReader.closed = true
pgconn.go#L2717: p.conn.resultReader.closed = true
pgconn.go#L2768: p.conn.resultReader = ResultReader{
pgconn.go#L2769: pgConn: p.conn,
pgconn.go#L2772: fieldDescriptions: p.conn.getFieldDescriptionSlice(len(msg.Fields)),
pgconn.go#L2774: convertRowDescription(p.conn.resultReader.fieldDescriptions, msg)
pgconn.go#L2775: return &p.conn.resultReader, nil
pgconn.go#L2780: p.conn.resultReader.closed = true
pgconn.go#L2793: p.conn.resultReader = ResultReader{
pgconn.go#L2794: commandTag: p.conn.makeCommandTag(msg.CommandTag),
pgconn.go#L2798: return &p.conn.resultReader, nil
pgconn.go#L2802: p.conn.resultReader.closed = true
pgconn.go#L2811: msg, err := p.conn.receiveMessage()
pgconn.go#L2814: p.conn.asyncClose()
pgconn.go#L2829: p.conn.asyncClose()
pgconn.go#L2842: p.conn.asyncClose()
pgconn.go#L2844: p.conn.contextWatcher.Unwatch()
pgconn.go#L2845: p.conn.unlock()
pgconn.go#L2856: p.conn.asyncClose()
pgconn.go#L2863: p.conn.asyncClose()
pgconn.go#L2871: p.conn.contextWatcher.Unwatch()
pgconn.go#L2872: p.conn.unlock()